package com.xdja.kafka.hdfs.sink.writer.definition;

import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.permission.FsAction;
import org.apache.hadoop.fs.permission.FsPermission;

import java.io.File;

/**
 * writer的基本定义
 */
public class WriterDefinition {
    /**
     *
     */
    public static String hdfsUrl;

    /**
     * 存放在hdfs的根路径
     */
    public static String hdfsPath;
    /**
     * hdfs文件系统
     */
    public static FileSystem fileSystem;

    /**
     * 777权限
     */
    public static FsPermission fsPermission_777 = new FsPermission(FsAction.ALL,FsAction.ALL,FsAction.ALL);
    /**
     * writer最多缓存个数
     */
    public final static int maxCacheSize = 5;


}
